8b6d2b2e6f76025709cbd62086657bb749c90f55,mpush-netty/src/main/java/com/mpush/netty/udp/NettyUDPConnector.java,NettyUDPConnector,createServer,#Listener#EventLoopGroup#ChannelFactory#,72

Before Change



            initOptions(b);

            ChannelFuture f = b.bind(port).sync();//直接绑定端�,��指定host,�然收�到组播消�

            if (f.isSuccess()) {
                Logs.Console.info("udp server start success on:{}", port);

After Change


            initOptions(b);

            //直接绑定端�,��指定host,�然收�到组播消�
            b.bind(port).addListener(future -> {
                if (future.isSuccess()) {
                    logger.info("udp server start success on:{}", port);
                    if (listener != null) listener.onSuccess(port);
                } else {
                    logger.error("udp server start failure on:{}", port, future.cause());
                    if (listener != null) listener.onFailure(future.cause());
                }
            });
        } catch (Exception e) {
            logger.error("udp server start exception", e);
            if (listener != null) listener.onFailure(e);